ebf018f97621eccd1ca423e1bbfdc036b6b46c2c,lens-server/src/main/java/org/apache/lens/server/scheduler/SchedulerServiceImpl.java,SchedulerServiceImpl,setStateOfJob,#SchedulerJobHandle#SchedulerJobEvent#,326

Before Change



  private int setStateOfJob(SchedulerJobHandle handle, SchedulerJobEvent event) throws LensException {
    try {
      SchedulerJobInfo info = schedulerDAO.getSchedulerJobInfo(handle);
      SchedulerJobState currentState = info.getJobState();
      SchedulerJobState nextState = currentState.nextTransition(event);
      info.setJobState(nextState);
      info.setModifiedOn(System.currentTimeMillis());
      return schedulerDAO.updateJobStatus(info);
    } catch (InvalidStateTransitionException e) {
      throw new LensException("Invalid state ", e);
    }

After Change


      SchedulerJobState nextState = currentState.nextTransition(event);
      info.setJobState(nextState);
      info.setModifiedOn(System.currentTimeMillis());
      int ret = schedulerDAO.updateJobStatus(info);
      if (ret == 1) {
        log.info("Successfully changed the status of job with handle {} from {} to {}", info.getId(), currentState,
          nextState);
      }
      return ret;
    } catch (InvalidStateTransitionException e) {
      throw new LensException("Invalid state ", e);
    }